package com.hr.reactive.flux;

import com.hr.reactive.common.Utils;
import reactor.core.publisher.Flux;

import java.util.function.Predicate;


/**
 * 对调试有帮助
 * @author Administrator
 */
public class Lec02FluxLog {
    public static void main(String[] args) {
        Flux.
                range(1,5).
                log().
                subscribe(Utils.subscriber());


    }
}
